package net.neptech.topics;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.kafka.config.TopicBuilder;

public class ClinicStaffTopics {

    public static final String  SLOT_USE_UPDATE  = "slot_use_update";
    public static  final  String CLINIC_ERROR_DLT = "clnicStaff.error.DLT";
    public static  final  String CLINIC_INSERT = "clinicStaff_insert";
    public static  final  String PUT_SLOT = "clinicStaff_put_slot";
//    public NewTopic slotUseUpdate() {
//        return TopicBuilder.name(SLOT_USE_UPDATE)
//                .partitions(3) //消费者数量
//                .replicas(1)//brow数量
//                .build();
//    }
}
